const cloud = require('wx-server-sdk')
cloud.init()

const db = cloud.database()
exports.main = async (event, context) => {
  console.log("开始查询并处理打卡任务列表......");
  let cdata = await db.collection('CLOCKTASK').where({
    
  }).get();
  console.log(cdata);

// try {


//   // 循环消息列表
//   const sendPromises = cdata.data.map(async message => {
    
//     try {
//       // 发送订阅消息
//       await cloud.openapi.subscribeMessage.send({
//         touser: message._openid,
//         page: 'pages/index/index',
//         data: {
//           thing4: {
//             value: '每日提肛打卡'
//           },
//           thing3: {
//             value: "防治脱肛、痔疮、阳痿、早泄、尿失禁、尿频等疾病"
//           }
//         },
//         templateId: 'xy8aGYNrimG5zACamsIWFZUPXTlM9r6U1_o0wwatR8U'
//       });
//       // 发送成功后将消息的状态改为已发送
//       return 1;
//     } catch (e) {
//       return e;
//     }
//   });

//   return Promise.all(sendPromises);
// } catch (err) {
//   console.log(err);
//   return err;
// }



    try {
      const result = await cloud.openapi.subscribeMessage.send({
        touser: 'oomR-5KXqNZ4W1TToBmE9IHCr6_c',
        page: 'pages/index/index',
        data: {
          thing4: {
            value: '每日提肛打卡'
          },
          thing3: {
            value: "防治脱肛、痔疮、阳痿、早泄、尿失禁、尿频等疾病"
          }
        },
        templateId: 'xy8aGYNrimG5zACamsIWFZUPXTlM9r6U1_o0wwatR8U'
      })
      console.log(result)
      return result;
    } catch (err) {
      console.log(err)
      return err;
    }

}